<?php

declare(strict_types=1);

namespace App\Chat\Process;

use Hyperf\AsyncQueue\Process\ConsumerProcess;
use Hyperf\Process\Annotation\Process;

#[Process(name: "local-async-queue")]
class AsyncQueueConsumer extends ConsumerProcess
{
    /**
     * @var string
     */
    protected string $queue = 'local';

    public function isEnable($server): bool
    {
        return \Hyperf\Support\env('LOCAL_QUEUE_ENABLE', true);
    }
}